package cn.yi.fast.mq.rocketmq.service;

import java.util.Map;

public interface MessageProducerService {

    void send(String  topic, String tag, String key, Map<String,Object> data, SendFail sendFail);


    @FunctionalInterface
    interface SendFail {
        void run();
    }
}
